package com.wuba.rxjavademo.tzx.filter;

import com.wuba.rxjavademo.tzx.common.Base;

/**
 * Created by tanzhenxing
 * Date: 2016/6/27.
 * Description:
 * distinct()函数来去除重复
 */
public class RxDistinct extends RxRepeat {
    public static void main(String[] args) {
        RxDistinct distinct = new RxDistinct();
        distinct.getObservable()
                .distinct()
                .subscribe(Base::print);
    }
}
